package com.ada.spark.action

import org.apache.spark.{SparkConf, SparkContext}

/**
  * 作用：在驱动程序中，以数组的形式返回数据集的所有元素。
  */
object Demo2_collect {
    def main(args: Array[String]): Unit = {
        //创建SparkConf
        val conf = new SparkConf().setAppName("Demo2_collect").setMaster("local[*]")
        //创建Spark上下文对象
        val sc = new SparkContext(conf)

        val rdd = sc.parallelize(1 to 10)

        //在驱动程序中，以数组的形式返回数据集的所有元素。
        println(rdd.collect.mkString(","))
        //1,2,3,4,5,6,7,8,9,10
    }
}
